package realtime.app.dws;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import realtime.util.EnvUtil;

public class DwsExamQuestionWindow {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = EnvUtil.getSEE(4);
        String topic = "dwd_test_exam_question";
        String groupId = "dws_exam_question_window_group";

    }
}
